package com.csdn.eval.spring.mqtt.core;

import com.csdn.eval.spring.mqtt.model.MqttEventAnnotationDefinition;
import org.springframework.messaging.MessageHeaders;

public interface MessageHandlerService<T> {

    default void doHandleMessage(String topic, T message, MessageHeaders headers, MqttEventAnnotationDefinition eventDefinition) {
    }

    default void doHandleMessage(String topic, byte[] message, MessageHeaders headers) {
    }

}
